package com.jry.gen.service;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.jry.common.core.constant.Constants;
import com.jry.common.core.constant.GenConstants;
import com.jry.common.core.exception.ServiceException;
import com.jry.common.core.text.CharsetKit;
import com.jry.common.core.utils.StringUtils;
import com.jry.common.core.utils.bean.BeanUtils;
import com.jry.common.core.web.domain.AjaxResult;
import com.jry.common.security.utils.SecurityUtils;
import com.jry.gen.domain.GenTable;
import com.jry.gen.domain.GenTable4Create;
import com.jry.gen.domain.GenTableColumn;
import com.jry.gen.domain.GenTableColumn4Create;
import com.jry.gen.mapper.DynamicTableMapper;
import com.jry.gen.mapper.GenTableColumnMapper;
import com.jry.gen.mapper.GenTableMapper;
import com.jry.gen.util.GenUtils;
import com.jry.gen.util.VelocityInitializer;
import com.jry.gen.util.VelocityUtils;
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.apache.velocity.Template;
import org.apache.velocity.VelocityContext;
import org.apache.velocity.app.Velocity;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.io.StringWriter;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
import java.util.zip.ZipEntry;
import java.util.zip.ZipOutputStream;

/**
 * 业务 服务层实现
 *
 * @author zhangsuhang
 */
@Service
public class GenTableServiceImpl implements IGenTableService {

    private static final Logger log = LoggerFactory.getLogger(GenTableServiceImpl.class);

    @Resource
    private GenTableMapper genTableMapper;

    @Resource
    private GenTableColumnMapper genTableColumnMapper;

    @Resource
    private DynamicTableMapper dynamicTableMapper;

    /**
     * 查询业务信息
     *
     * @param id 业务ID
     * @return 业务信息
     */
    @Override
    public GenTable selectGenTableById(Long id) {
        GenTable genTable = genTableMapper.selectGenTableById(id);
        setTableFromOptions(genTable);
        return genTable;
    }

    /**
     * 查询业务列表
     *
     * @param genTable 业务信息
     * @return 业务集合
     */
    @Override
    public List<GenTable> selectGenTableList(GenTable genTable) {
        return genTableMapper.selectGenTableList(genTable);
    }

    /**
     * 查询据库列表
     *
     * @param genTable 业务信息
     * @return 数据库表集合
     */
    @Override
    public List<GenTable> selectDbTableList(GenTable genTable) {
        return genTableMapper.selectDbTableList(genTable);
    }

    /**
     * 查询据库列表
     *
     * @param tableNames 表名称组
     * @return 数据库表集合
     */
    @Override
    public List<GenTable> selectDbTableListByNames(String[] tableNames) {
        return genTableMapper.selectDbTableListByNames(tableNames);
    }

    /**
     * 查询所有表信息
     *
     * @return 表信息集合
     */
    @Override
    public List<GenTable> selectGenTableAll() {
        return genTableMapper.selectGenTableAll();
    }

    /**
     * 修改业务
     *
     * @param genTable 业务信息
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateGenTable(GenTable genTable) {
        String options = JSON.toJSONString(genTable.getParams());
        genTable.setOptions(options);
        int row = genTableMapper.updateGenTable(genTable);
        if (row > 0) {
            for (GenTableColumn cenTableColumn : genTable.getColumns()) {
                genTableColumnMapper.updateGenTableColumn(cenTableColumn);
            }
        }
    }

    /**
     * 删除业务对象
     *
     * @param tableIds 需要删除的数据ID
     * @return 结果
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteGenTableByIds(Long[] tableIds) {
        genTableMapper.deleteGenTableByIds(tableIds);
        genTableColumnMapper.deleteGenTableColumnByIds(tableIds);
    }

    /**
     * 导入表结构
     *
     * @param tableList 导入表列表
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void importGenTable(List<GenTable> tableList) {
        String operName = SecurityUtils.getUsername();
        try {
            for (GenTable table : tableList) {
                String tableName = table.getTableName();
                GenUtils.initTable(table, operName);
                int row = genTableMapper.insertGenTable(table);
                if (row > 0) {
                    // 保存列信息
                    List<GenTableColumn> genTableColumns = genTableColumnMapper
                            .selectDbTableColumnsByName(tableName);
                    for (GenTableColumn column : genTableColumns) {
                        GenUtils.initColumnField(column, table);
                        genTableColumnMapper.insertGenTableColumn(column);
                    }
                }
            }
        } catch (Exception e) {
            throw new ServiceException("导入失败：" + e.getMessage());
        }
    }

    /**
     * 预览代码
     *
     * @param tableId 表编号
     * @return 预览数据列表
     */
    @Override
    public Map<String, String> previewCode(Long tableId) {
        Map<String, String> dataMap = new LinkedHashMap<>();
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableById(tableId);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);
        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateList(table.getTplCategory());
        for (String template : templates) {
            // 渲染模板
            StringWriter sw = new StringWriter();
            Template tpl = Velocity.getTemplate(template, Constants.UTF8);
            tpl.merge(context, sw);
            dataMap.put(template, sw.toString());
        }
        return dataMap;
    }

    /**
     * 预览代码
     *
     * @param tableId 表编号
     * @return 预览数据列表
     */
    @Override
    public Map<String, String> previewCodePlus(Long tableId) {
        Map<String, String> dataMap = new LinkedHashMap<>();
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableById(tableId);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);
        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateListPlus(table.getTplCategory());
        for (String template : templates) {
            // 渲染模板
            StringWriter sw = new StringWriter();
            Template tpl = Velocity.getTemplate(template, Constants.UTF8);
            tpl.merge(context, sw);
            dataMap.put(template, sw.toString());
        }
        return dataMap;
    }

    /**
     * 生成代码（下载方式）
     *
     * @param tableName 表名称
     * @return 数据
     */
    @Override
    public byte[] downloadCode(String tableName) {
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        ZipOutputStream zip = new ZipOutputStream(outputStream);
        generatorCode(tableName, zip);
        IOUtils.closeQuietly(zip);
        return outputStream.toByteArray();
    }

    /**
     * 生成代码（自定义路径）
     *
     * @param tableName 表名称
     */
    @Override
    public void generatorCode(String tableName) {
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableByName(tableName);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);

        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateList(table.getTplCategory());
        for (String template : templates) {
            if (!StringUtils
                    .containsAny(template, "sql.vm", "api.js.vm", "index.vue.vm", "index-tree.vue.vm")) {
                // 渲染模板
                StringWriter sw = new StringWriter();
                Template tpl = Velocity.getTemplate(template, Constants.UTF8);
                tpl.merge(context, sw);
                try {
                    String path = getGenPath(table, template);
                    FileUtils.writeStringToFile(new File(path), sw.toString(), CharsetKit.UTF_8);
                } catch (IOException e) {
                    throw new ServiceException("渲染模板失败，表名：" + table.getTableName());
                }
            }
        }
    }

    /**
     * 生成代码Plus（自定义路径）
     *
     * @param tableName 表名称
     */
    @Override
    public void generatorCodePlus(String tableName) {
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableByName(tableName);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);

        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateListPlus(table.getTplCategory());
        for (String template : templates) {
            if (!StringUtils
                    .containsAny(template, "sql.vm", "api.plus.js.vm", "index.plus.vue.vm", "index-tree.plus.vue.vm")) {
                // 渲染模板
                StringWriter sw = new StringWriter();
                Template tpl = Velocity.getTemplate(template, Constants.UTF8);
                tpl.merge(context, sw);
                try {
                    String path = getGenPathPlus(table, template);
                    FileUtils.writeStringToFile(new File(path), sw.toString(), CharsetKit.UTF_8);
                } catch (IOException e) {
                    throw new ServiceException("渲染模板失败，表名：" + table.getTableName());
                }
            }
        }
    }

    /**
     * 同步数据库
     *
     * @param tableName 表名称
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void synchDb(String tableName) {
        GenTable table = genTableMapper.selectGenTableByName(tableName);
        List<GenTableColumn> tableColumns = table.getColumns();
        Map<String, GenTableColumn> tableColumnMap = tableColumns.stream()
                .collect(Collectors.toMap(GenTableColumn::getColumnName, Function.identity()));

        List<GenTableColumn> dbTableColumns = genTableColumnMapper
                .selectDbTableColumnsByName(tableName);
        if (StringUtils.isEmpty(dbTableColumns)) {
            throw new ServiceException("同步数据失败，原表结构不存在");
        }
        List<String> dbTableColumnNames = dbTableColumns.stream().map(GenTableColumn::getColumnName)
                .collect(Collectors.toList());

        dbTableColumns.forEach(column -> {
            GenUtils.initColumnField(column, table);
            if (tableColumnMap.containsKey(column.getColumnName())) {
                GenTableColumn prevColumn = tableColumnMap.get(column.getColumnName());
                column.setColumnId(prevColumn.getColumnId());
                if (column.isList()) {
                    // 如果是列表，继续保留查询方式/字典类型选项
                    column.setDictType(prevColumn.getDictType());
                    column.setQueryType(prevColumn.getQueryType());
                }
                if (StringUtils.isNotEmpty(prevColumn.getIsRequired()) && !column.isPk()
                        && (column.isInsert() || column.isEdit())
                        && ((column.isUsableColumn()) || (!column.isSuperColumn()))) {
                    // 如果是(新增/修改&非主键/非忽略及父属性)，继续保留必填/显示类型选项
                    column.setIsRequired(prevColumn.getIsRequired());
                    column.setHtmlType(prevColumn.getHtmlType());
                }
                genTableColumnMapper.updateGenTableColumn(column);
            } else {
                genTableColumnMapper.insertGenTableColumn(column);
            }
        });

        List<GenTableColumn> delColumns = tableColumns.stream()
                .filter(column -> !dbTableColumnNames.contains(column.getColumnName()))
                .collect(Collectors.toList());
        if (StringUtils.isNotEmpty(delColumns)) {
            genTableColumnMapper.deleteGenTableColumns(delColumns);
        }
    }

    /**
     * 批量生成代码（下载方式）
     *
     * @param tableNames 表数组
     * @return 数据
     */
    @Override
    public byte[] downloadCode(String[] tableNames) {
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        ZipOutputStream zip = new ZipOutputStream(outputStream);
        for (String tableName : tableNames) {
            generatorCode(tableName, zip);
        }
        IOUtils.closeQuietly(zip);
        return outputStream.toByteArray();
    }

    /**
     * 批量生成代码（下载方式）
     *
     * @param tableNames 表数组
     * @return 数据
     */
    @Override
    public byte[] downloadCodePlus(String[] tableNames) {
        ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
        ZipOutputStream zip = new ZipOutputStream(outputStream);
        for (String tableName : tableNames) {
            generatorCodePlus(tableName, zip);
        }
        IOUtils.closeQuietly(zip);
        return outputStream.toByteArray();
    }

    /**
     * 查询表信息并生成代码
     */
    private void generatorCode(String tableName, ZipOutputStream zip) {
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableByName(tableName);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);

        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateList(table.getTplCategory());
        for (String template : templates) {
            // 渲染模板
            StringWriter sw = new StringWriter();
            Template tpl = Velocity.getTemplate(template, Constants.UTF8);
            tpl.merge(context, sw);
            try {
                // 添加到zip
                zip.putNextEntry(new ZipEntry(VelocityUtils.getFileName(template, table)));
                IOUtils.write(sw.toString(), zip, Constants.UTF8);
                IOUtils.closeQuietly(sw);
                zip.flush();
                zip.closeEntry();
            } catch (IOException e) {
                log.error("渲染模板失败，表名：" + table.getTableName() + ", msg:{}", e.getMessage());
            }
        }
    }

    /**
     * 查询表信息并生成代码
     */
    private void generatorCodePlus(String tableName, ZipOutputStream zip) {
        // 查询表信息
        GenTable table = genTableMapper.selectGenTableByName(tableName);
        // 设置主子表信息
        setSubTable(table);
        // 设置主键列信息
        setPkColumn(table);

        VelocityInitializer.initVelocity();

        VelocityContext context = VelocityUtils.prepareContext(table);

        // 获取模板列表
        List<String> templates = VelocityUtils.getTemplateListPlus(table.getTplCategory());
        for (String template : templates) {
            // 渲染模板
            StringWriter sw = new StringWriter();
            Template tpl = Velocity.getTemplate(template, Constants.UTF8);
            tpl.merge(context, sw);
            try {
                // 添加到zip
                zip.putNextEntry(new ZipEntry(VelocityUtils.getFileNamePlus(template, table)));
                IOUtils.write(sw.toString(), zip, Constants.UTF8);
                IOUtils.closeQuietly(sw);
                zip.flush();
                zip.closeEntry();
            } catch (IOException e) {
                log.error("渲染模板失败，表名：" + table.getTableName() + ", msg:{}", e.getMessage());
            }
        }
    }

    /**
     * 修改保存参数校验
     *
     * @param genTable 业务信息
     */
    @Override
    public void validateEdit(GenTable genTable) {
        if (GenConstants.TPL_TREE.equals(genTable.getTplCategory())) {
            String options = JSON.toJSONString(genTable.getParams());
            JSONObject paramsObj = JSONObject.parseObject(options);
            if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_CODE))) {
                throw new ServiceException("树编码字段不能为空");
            } else if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_PARENT_CODE))) {
                throw new ServiceException("树父编码字段不能为空");
            } else if (StringUtils.isEmpty(paramsObj.getString(GenConstants.TREE_NAME))) {
                throw new ServiceException("树名称字段不能为空");
            } else if (GenConstants.TPL_SUB.equals(genTable.getTplCategory())) {
                if (StringUtils.isEmpty(genTable.getSubTableName())) {
                    throw new ServiceException("关联子表的表名不能为空");
                } else if (StringUtils.isEmpty(genTable.getSubTableFkName())) {
                    throw new ServiceException("子表关联的外键名不能为空");
                }
            }
        }
    }

    /**
     * 设置主键列信息
     *
     * @param table 业务表信息
     */
    public void setPkColumn(GenTable table) {
        for (GenTableColumn column : table.getColumns()) {
            if (column.isPk()) {
                table.setPkColumn(column);
                break;
            }
        }
        if (StringUtils.isNull(table.getPkColumn())) {
            table.setPkColumn(table.getColumns().get(0));
        }
        if (GenConstants.TPL_SUB.equals(table.getTplCategory())) {
            for (GenTableColumn column : table.getSubTable().getColumns()) {
                if (column.isPk()) {
                    table.getSubTable().setPkColumn(column);
                    break;
                }
            }
            if (StringUtils.isNull(table.getSubTable().getPkColumn())) {
                table.getSubTable().setPkColumn(table.getSubTable().getColumns().get(0));
            }
        }
    }

    /**
     * 设置主子表信息
     *
     * @param table 业务表信息
     */
    public void setSubTable(GenTable table) {
        String subTableName = table.getSubTableName();
        if (StringUtils.isNotEmpty(subTableName)) {
            table.setSubTable(genTableMapper.selectGenTableByName(subTableName));
        }
    }

    /**
     * 设置代码生成其他选项值
     *
     * @param genTable 设置后的生成对象
     */
    public void setTableFromOptions(GenTable genTable) {
        JSONObject paramsObj = JSONObject.parseObject(genTable.getOptions());
        if (StringUtils.isNotNull(paramsObj)) {
            String treeCode = paramsObj.getString(GenConstants.TREE_CODE);
            String treeParentCode = paramsObj.getString(GenConstants.TREE_PARENT_CODE);
            String treeName = paramsObj.getString(GenConstants.TREE_NAME);
            String parentMenuId = paramsObj.getString(GenConstants.PARENT_MENU_ID);
            String parentMenuName = paramsObj.getString(GenConstants.PARENT_MENU_NAME);

            genTable.setTreeCode(treeCode);
            genTable.setTreeParentCode(treeParentCode);
            genTable.setTreeName(treeName);
            genTable.setParentMenuId(parentMenuId);
            genTable.setParentMenuName(parentMenuName);
        }
    }

    /**
     * 获取代码生成地址
     *
     * @param table    业务表信息
     * @param template 模板文件路径
     * @return 生成地址
     */
    public static String getGenPath(GenTable table, String template) {
        String genPath = table.getGenPath();
        if (StringUtils.equals(genPath, "/")) {
            return System.getProperty("user.dir") + File.separator + "src" + File.separator
                    + VelocityUtils.getFileName(template, table);
        }
        return genPath + File.separator + VelocityUtils.getFileName(template, table);
    }

    /**
     * 获取代码生成地址
     *
     * @param table    业务表信息
     * @param template 模板文件路径
     * @return 生成地址
     */
    public static String getGenPathPlus(GenTable table, String template) {
        String genPath = table.getGenPath();
        if (StringUtils.equals(genPath, "/")) {
            return System.getProperty("user.dir") + File.separator + "src" + File.separator
                    + VelocityUtils.getFileNamePlus(template, table);
        }
        return genPath + File.separator + VelocityUtils.getFileNamePlus(template, table);
    }

    @Transactional(rollbackFor = {Exception.class, RuntimeException.class})
    @Override
    public AjaxResult createTable(GenTable4Create genTable4Create) {
        try {
            String splitElement = "_";
            GenTable genTable = new GenTable();
            String tableName = genTable4Create.getTableName();
            String packageName = tableName.substring(0, tableName.indexOf(splitElement));
            String businessName = tableName.substring(tableName.indexOf(splitElement) + 1);
            businessName = removeUnderline(businessName, splitElement);
            genTable.setTableName(tableName);
            genTable.setTableComment(genTable4Create.getTableComment());
            String clazzName = StringUtils.toCamelCase(genTable.getTableName());
            clazzName = clazzName.substring(0, 1).toUpperCase() + clazzName.substring(1);
            genTable.setClassName(clazzName);
            genTable.setTplCategory(GenConstants.TPL_CRUD);
            if("ywzx".equals(packageName)) {
                genTable.setPackageName(GenConstants.CREATE_PACKAGE_NAME_PRE + GenConstants.CREATE_MODULE_YWZX);
                genTable.setModuleName(GenConstants.CREATE_MODULE_YWZX);
            } else {
                genTable.setPackageName(GenConstants.CREATE_PACKAGE_NAME_PRE + packageName);
                genTable.setModuleName(packageName);
            }
            genTable.setBusinessName(businessName);
            genTable.setFunctionName(genTable.getTableComment());
            genTable.setFunctionAuthor(SecurityUtils.getUsername());
            genTable.setGenType("0");
            genTable.setGenPath("/");
            Map<String, Object> params = new HashMap<>();
            params.put("parentMenuId", "1090");
            String options = JSON.toJSONString(params);
            genTable.setOptions(options);
            genTable.setCreateBy(SecurityUtils.getUsername());
            genTable.setCreateTime(new Date());
            genTableMapper.insertGenTable(genTable);
            Long tableId = genTable.getTableId();
            int autoNum = 0;
            List<GenTableColumn> genTableColumnList = new ArrayList<>();
            int i = 1;
            for (GenTableColumn4Create column : genTable4Create.getColumns()) {
                GenTableColumn genTableColumn = new GenTableColumn();
                BeanUtils.copyBeanProp(genTableColumn, column);
                if (column.getAutoInct() != null && column.getAutoInct() == 1) {
                    if (column.getPrimaryKey() == null || column.getPrimaryKey() != 1) {
                        throw new Exception("自增字段必须为主键");
                    } else {
                        genTableColumn.setIsPk("1");
                        genTableColumn.setIsIncrement("1");
                    }
                    autoNum++;
                }
                if (autoNum > 1) {
                    throw new Exception("自增字段只能为一个");
                }
                genTableColumn.setTableId(tableId);
                genTableColumn.setCreateBy(SecurityUtils.getUsername());
                genTableColumn.setColumnType(getColumnType(column.getColumnType(), column.getColumnLength(), column.getDecimalPoint()));
                genTableColumn.setSort(i++);
                if(StringUtils.isEmpty(column.getDictType())) {
                    genTableColumn.setDictType("");
                }
                genTableColumnList.add(genTableColumn);
            }
            genTableColumnMapper.insertGenTableColumnList(genTableColumnList);

            //生成sql部分
            StringBuilder builder = new StringBuilder();
            builder.append("CREATE TABLE IF NOT EXISTS " + tableName + " (");
            String keyStr = "";
            for (GenTableColumn4Create column : genTable4Create.getColumns()) {
                String isnull = " DEFAULT NULL ";
                if (StringUtils.isNotNull(column.getIsRequired()) && "1".equals(column.getIsRequired())) {
                    isnull = " NOT NULL ";
                }
                String columnComment = "";
                if (StringUtils.isNotBlank(column.getColumnComment())) {
                    columnComment = " COMMENT '" + column.getColumnComment() + "' ";
                }
                if (column.getPrimaryKey() != null && column.getPrimaryKey() == 1) {
                    keyStr += "," + column.getColumnName();
                    isnull = " NOT NULL ";
                    if(column.getAutoInct() != null && column.getAutoInct() == 1){
                        isnull += " AUTO_INCREMENT ";
                    }
                }
                if("timestamp".equals(column.getColumnType()) && " DEFAULT NULL ".equals(isnull)) {
                    isnull = "";
                }
                builder.append(column.getColumnName() + " " + getColumnType(column.getColumnType(), column.getColumnLength(), column.getDecimalPoint())
                        + isnull + columnComment + ",");
            }
            if (StringUtils.isNotBlank(keyStr)) {
                keyStr = "PRIMARY KEY (" + keyStr.substring(1) + ") USING BTREE";
            }else {
                builder.deleteCharAt(builder.length() -1);
            }
            builder.append(keyStr + ")");
            if(StringUtils.isNotBlank(genTable4Create.getTableComment())){
                builder.append(" COMMENT='" +genTable4Create.getTableComment()+ "'");
            }
//            log.info("SQL：" + builder.toString());
            dynamicTableMapper.createTable(builder.toString());

            return AjaxResult.success();
        } catch (Exception e) {
            log.error("创建代码生成表异常：{}" + e.getMessage());
            throw new RuntimeException(e);
        }
    }

    private String removeUnderline(String req, String element) {
        if(req.indexOf(element) != -1) {
            req = req.replaceAll(element, "");
        }
        return req;
    }

    private String getColumnType(String type, Integer le, Integer decimalPoint) {
        decimalPoint = decimalPoint == null ? 0 : decimalPoint;
        le = le == null ? 0 : le;
        String numStr = "(10)";
        if (le != null) {
            numStr = "(" + le + ")";
        }
        switch (type) {
            case "char":
                return "char" + numStr;
            case "varchar":
                return "varchar" + numStr;
            case "varbinary":
                return "varbinary" + numStr;
            case "bigint":
                return "bigint" + numStr;
            case "int":
                return "int" + numStr;
            case "tinyint":
                return "tinyint" + numStr;
            case "tinytext":
                return "tinytext" + numStr;
            case "longblob":
                return "longblob" + numStr;
            case "longtext":
                return "longtext";
            case "date":
                return "date";
            case "datetime":
                return "datetime";
            case "decimal":
                return "decimal(" + le + "," + decimalPoint + ")";
            case "double":
                return "double(" + le + "," + decimalPoint + ")";
            case "float":
                return "float(" + le + "," + decimalPoint + ")";
            case "text":
                return "text";
            case "time":
                return "time";
            case "timestamp":
                return "timestamp";
            case "tinyblob":
                return "tinyblob";
            case "binary":
                return "binary" + numStr;
            case "blob":
                return "blob";
            case "year":
                return "year";
            default:
                return "varchar(255)";
        }
    }

}
